package com.chukun.tx.message.producer;

import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;

public class MqMessageSendCallback implements SendCallback {

    @Override
    public void onSuccess(SendResult sendResult) {}

    @Override
    public void onException(Throwable e) {
       throw new RuntimeException(e);
    }
}
